package com.reload.core;

import reactor.core.publisher.Flux;

/**
 * @Date: 2024/12/5 16:06
 * @Author: jianchenlong
 * @Description: 自定义处理规则
 */
public class Handle {
    public static void main(String[] args) {
        handle();
    }

    // 自定义流中元素的处理规则
    public static void handle() {
        Flux.range(1, 10)
                // 自定义规则
                .handle((value, sink) -> {
                    System.out.println("拿到的值：" + value);
                    // 可以向下发送数据的通道
                    sink.next("user: " + value);
                })
                .log()
                .subscribe(System.out::println);
    }
}
